Skip to content

채팅 메시지 카프카 발행 및 수신 로직 구현 #132

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Merged
ki-met-hoon merged 12 commits into from
Feb 4, 2025
Merged

채팅 메시지 카프카 발행 및 수신 로직 구현 #132

ki-met-hoon merged 12 commits into from
Feb 4, 2025

Conversation

@ki-met-hoon
Copy link
Collaborator

@ki-met-hoon ki-met-hoon commented Feb 4, 2025

Pull request

Related issue

Resolve #118
Resolve #130

Motivation and context

  • 채팅 메시지 카프카 발행 로직
  • 카프카로부터 메시지 수신 로직

Solution

  • 채팅 메시지 전달 시 채팅방 ID를 키 값으로 전달해 메시지 순서 보장
    • 실시간 성이 떨어짐
    • 더 나은 방법이 없는지 고민해보겠습니다.
  • 각 채팅 서버 별로 컨슈머 그룹 설정
  • 파티션 수에 맞게 멀티 컨슈머 스레드 설정
  • 보람님 추가 기능 구현
    • 로컬 메모리와 유저 ID를 비교하는 로직, 있으면 웹소켓을 통한 데이터 전달 없으면 일단 버림
    • 웹소켓 전달하는 로직 or 전달하는 함수
    • ChatMessageToKafka DTO 수정

How has this been tested

Types of changes

  • Bug fix (non-breaking change which fixes an issue)
  • New feature (non-breaking change which adds functionality)
  • Breaking change (fix or feature that would cause existing functionality to change)

Checklist

  • My code follows the code style of this project.
  • My change requires a change to the documentation.
  • I have updated the documentation accordingly.
  • I have read the docs/CONTRIBUTING.md document.
  • I have added tests to cover my changes.
  • All new and existing tests passed.

@ki-met-hoon
#118 build(be): kafka 의존성 추가
ae04641
@ki-met-hoon
#118 build(be): kafka consumer 환경 설정
324d323
@ki-met-hoon
#118 feat(be): processMinutePriceMessage method 구현
ff532cb 
- KafkaListener 이용
@ki-met-hoon
#118 feat(be): MinutePriceResponse DTO 구현
510ca89
@ki-met-hoon
#114 build(be): RoundRobinPartitioner 설정
f3c9d0d 
- 최소한의 메시지 순서 보장을 위한 파티셔너 설정
- 라운드 로빈 방식으로 임시 처리
@ki-met-hoon
#114 remove(be): 라운드로빈 파티셔닝 설정 삭제
86e7cf2
@ki-met-hoon
#118 refactor(be): processMinutePrice method
7997ccc
@ki-met-hoon
#130 build(be): Gson 의존성 추가
bd33214
@ki-met-hoon
#130 feat(be): ChatMessageToKafka DTO 구현
402b2fe 
- 추후 보람님 리팩토링 예정
@ki-met-hoon
#118 feat(be): processChatMessage method 구현
d38ca43 
- 컨슈머 스레드 2, 파티션의 개수와 맞게 병렬 처리
@ki-met-hoon
#130 build(be): producer 설정
4bc8bbc
@ki-met-hoon
#130 feat(be): sendChatMessage method 구현
327577c 
- roomID를 키 값으로 메시지 순서 보장
@ki-met-hoon ki-met-hoon added ✨ Feature 기능 추가 📦 Environment 개발 환경 세팅 🎮 BE 백엔드 ♻️ Need To Refactor 추후 리팩토링이 필요한 이슈 및 논의 상 무조건 스프린트내에 해야하는 것들 labels Feb 4, 2025
@ki-met-hoon ki-met-hoon added this to the 주톡피아 마일스톤2 milestone Feb 4, 2025
@ki-met-hoon ki-met-hoon self-assigned this Feb 4, 2025
@bo-ram-bo-ram
Copy link
Member

bo-ram-bo-ram commented Feb 4, 2025

LGTM

@ki-met-hoon ki-met-hoon merged commit 37ecb3a into dev Feb 4, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

@ki-met-hoon ki-met-hoon

Labels

🎮 BE 백엔드 📦 Environment 개발 환경 세팅 ✨ Feature 기능 추가 ♻️ Need To Refactor 추후 리팩토링이 필요한 이슈 및 논의 상 무조건 스프린트내에 해야하는 것들

Projects

None yet

Milestone

주톡피아 마일스톤2

Development

Successfully merging this pull request may close these issues.

채팅 메시지 카프카 전달 및 수신 기능 구현 채팅 서버 주식 당일일분봉 데이터 Consumer 구현

3 participants

@ki-met-hoon @bo-ram-bo-ram